//package com.ruoyi.web.controller.system;
//
//import com.alibaba.fastjson2.JSON;
//import com.ruoyi.common.core.domain.SensorData;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.OnClose;
//import javax.websocket.OnOpen;
//import javax.websocket.Session;
//import javax.websocket.server.PathParam;
//import javax.websocket.server.ServerEndpoint;
//import java.io.IOException;
//import java.util.Collections;
//import java.util.HashSet;
//import java.util.List;
//import java.util.Set;
//
//@ServerEndpoint("/traffic")
//@Component
//public class WebSocketServer {
//    private static final Set<Session> sessions = Collections.synchronizedSet(new HashSet<>());
//
//    /**
//     * 接收 userId
//     */
//    private String userId = "";
//
//    @OnOpen
//    public void onOpen(Session session) {
//        sessions.add(session);
//    }
//
//    @OnClose
//    public void onClose(Session session) {
//        sessions.remove(session);
//    }
//
//    public static void sendToAll(List<Integer> data) {
//        String json = JSON.toJSONString(data);
//        sessions.forEach(session -> {
//            try {
//                session.getBasicRemote().sendText(json);
//            } catch (IOException e) {
//                System.err.println("WebSocket发送失败: " + e.getMessage());
//            }
//        });
//    }
//}